package org.ykhl.mq.commons.receiver;

import org.ykhl.mq.commons.BaseMessage;

public interface MessageListener {
	public MessageConsumeStatus consume(BaseMessage msg);
}
